package com.gao.t_arrayblockingqueue;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.TimeUnit;

/**
 * @author gao
 * @time 2021/04/20 22:28:19
 * ArrayBlockingQueue
 * 1. add/element   是一对
 * 2. put/take      是一对
 * 3. offer/poll    是一对
 */
public class App {
    public static void main(String[] args) throws InterruptedException {
        ArrayBlockingQueue queue = new ArrayBlockingQueue(10);

        // 查看源码
        queue.add(1);

        // 查看源码
        queue.element();

        // 查看源码
        queue.put(1);

        // 查看源码
        queue.take();

        // 查看源码
        queue.offer(1);

        // 查看源码
        queue.poll();

        // 查看源码
        queue.offer(1, 100, TimeUnit.SECONDS);

        // 查看源码
        queue.poll( 100, TimeUnit.SECONDS);
    }
}
